fa7df52f4add7663cef207819ff05b03745df2b7,kafka-scheduler/src/main/java/org/apache/mesos/kafka/scheduler/KafkaScheduler.java,KafkaScheduler,KafkaScheduler,#KafkaSchedulerConfiguration#Environment#,65

Before Change



    stageScheduler = new DefaultStageScheduler(offerAccepter);
    repairScheduler = new KafkaRepairScheduler(
        configState.getTargetName(),
        kafkaState,
        offerRequirementProvider,
        offerAccepter);

After Change



    stageScheduler = new DefaultStageScheduler(offerAccepter);
    repairScheduler = new KafkaRepairScheduler(
        configState.getTargetName().toString(),
        kafkaState,
        offerRequirementProvider,
        offerAccepter);